package site.teamo.biu.flink.function.process;

import cn.hutool.json.JSONObject;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.functions.ProcessFunction;
import org.apache.flink.util.Collector;
import site.teamo.biu.flink.sdk.annotation.function.BFProcessFunction;
import site.teamo.biu.flink.sdk.function.AbstractProcessFunction;
import site.teamo.biu.flink.sdk.job.JobContext;

/**
 * @author haocongshun
 * @date 2023/07/27 15:41:46
 */
@BFProcessFunction(
        in = JSONObject.class,
        out = JSONObject.class
)
public class JSONMappingFunction extends AbstractProcessFunction<JSONObject, JSONObject> {
    public JSONMappingFunction(String name, JobContext context) {
        super(name, context);
    }

    @Override
    public void open(Configuration parameters) throws Exception {
        super.open(parameters);
    }

    @Override
    public void processElement(JSONObject jsonObject, ProcessFunction<JSONObject, JSONObject>.Context context, Collector<JSONObject> collector) throws Exception {


    }
}
